package com.songjia.stream.test01;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.cloud.stream.messaging.Source;

@EnableBinding({ Sink.class, Source.class })
public class MyReceiver {

	@StreamListener(Sink.INPUT)
	public void hendle(String message) {
		System.out.println("MyReceiver收到消息：" + message);
	}
}
